# celery启动文件
from celery import Celery
import os

os.environ.setdefault("DJANGO_SETTINGS_MODULE", "hunqing2021.settings.dev")

# 创建celery客户端对象
celery_app = Celery('hunqing')
# 加载celery配置，指定celery生产的任务存放在哪里
celery_app.config_from_object('celery_tasks.config')
# 注册celery可以生产什么任务
celery_app.autodiscover_tasks(['celery_tasks.sms','celery_tasks.email'])

# celery -A celery_tasks.main worker -l info -P eventlet